package com.rpc.core.constant;

import com.rpc.core.holder.transmit.Request;
import com.rpc.core.holder.transmit.Response;
import io.netty.channel.nio.NioEventLoopGroup;

public class ClientLoop {


    private static NioEventLoopGroup nioEventLoopGroup;

    public static NioEventLoopGroup getLoop(){
        if (nioEventLoopGroup == null) {
            synchronized (ClientLoop.class) {
                if (nioEventLoopGroup == null) {
                    //shutdownGracefully
                    nioEventLoopGroup = new NioEventLoopGroup();
                }
            }
        }
        return nioEventLoopGroup;
    }


    public static void close(){
        if(nioEventLoopGroup!=null){
            nioEventLoopGroup.shutdownGracefully();
        }

    }
}
